home
***
CD-ROM
|
disk
|
FTP
|
other
***
search
/
Windows Game Programming for Dummies (2nd Edition)
/
WinGamProgFD.iso
/
mac
/
DirectX SDK
/
DXSDK
/
samples
/
Multimedia
/
DirectPlay
/
Tutorials
/
Tut08_Voice
/
Voice.cpp
< prev
next >
Wrap
C/C++ Source or Header
|
2001-10-08
|
41KB
|
1,240 lines
//----------------------------------------------------------------------------
// File: Voice.cpp
//
// Desc: This simple program builds upon the last tutorial and adds voice support
//
// Copyright (c) 2000-2001 Microsoft Corp. All rights reserved.
//-----------------------------------------------------------------------------
#define INITGUID
#define _WIN32_DCOM
#include <stdio.h>
#include <dplay8.h>
#include <dplobby8.h>
#include <dvoice.h>
//-----------------------------------------------------------------------------
// App specific structures
//-----------------------------------------------------------------------------
struct HOST_NODE
{
DPN_APPLICATION_DESC* pAppDesc;
IDirectPlay8Address* pHostAddress;
WCHAR* pwszSessionName;
HOST_NODE* pNext;
};
//-----------------------------------------------------------------------------
// Global variables
//-----------------------------------------------------------------------------
IDirectPlay8Peer* g_pDP = NULL;
IDirectPlay8LobbiedApplication* g_pLobbyApp = NULL;
IDirectPlay8Address* g_pDeviceAddress = NULL;
IDirectPlay8Address* g_pHostAddress = NULL;
IDirectPlayVoiceClient* g_pVoiceClient = NULL;
IDirectPlayVoiceServer* g_pVoiceServer = NULL;
DPNHANDLE g_hLobbyHandle = NULL;
BOOL g_bLobbyLaunched = FALSE;
BOOL g_bHost;
BOOL g_bRegister = FALSE;
BOOL g_bUnRegister = FALSE;
WCHAR* g_wszPath = NULL;
HOST_NODE* g_pHostList = NULL;
CRITICAL_SECTION g_csHostList;
DPNID g_dpnidLocalPlayer = 0;
// This GUID allows DirectPlay to find other instances of the same game on
// the network. So it must be unique for every game, and the same for
// every instance of that game. // {91F570F2-CE88-428a-8025-25A1E4918B44}
GUID g_guidApp = { 0x91f570f2, 0xce88, 0x428a, { 0x80, 0x25, 0x25, 0xa1, 0xe4, 0x91, 0x8b, 0x44 } };
//-----------------------------------------------------------------------------
// Function-prototypes
//-----------------------------------------------------------------------------
HRESULT WINAPI DirectPlayMessageHandler(PVOID pvUserContext, DWORD dwMessageId, PVOID pMsgBuffer);
HRESULT WINAPI LobbyAppMessageHandler(PVOID pvUserContext, DWORD dwMessageId, PVOID pMsgBuffer);
HRESULT WINAPI DirectVoiceServerMessageHandler(PVOID pvUserContext, DWORD dwMessageId, PVOID pMsgBuffer);
HRESULT WINAPI DirectVoiceClientMessageHandler(PVOID pvUserContext, DWORD dwMessageId, PVOID pMsgBuffer);
BOOL IsServiceProviderValid(const GUID* pGuidSP);
HRESULT InitDirectPlay();
HRESULT InitDirectPlayVoice();
HRESULT CreateDeviceAddress();
HRESULT CreateHostAddress(WCHAR* pwszHost);
HRESULT HostSession();
HRESULT EnumDirectPlayHosts();
HRESULT ConnectToSession();
HRESULT SendDirectPlayMessage();
HRESULT Register();
HRESULT UnRegister();
HRESULT LobbyLaunch();
HRESULT TestDirectVoice();
HWND GetConsoleHwnd();
void CleanupDirectPlay();
//-----------------------------------------------------------------------------
// Miscellaneous helper functions
//-----------------------------------------------------------------------------
#define SAFE_DELETE(p) {if(p) {delete (p); (p)=NULL;}}
#define SAFE_DELETE_ARRAY(p) {if(p) {delete[] (p); (p)=NULL;}}
#define SAFE_RELEASE(p) {if(p) {(p)->Release(); (p)=NULL;}}
#define USER_HOST 1
#define USER_CONNECT 2
#define USER_EXIT 1
#define USER_SEND 2
#define CMDLINE_REGISTER "register"
#define CMDLINE_UNREGISTER "unregister"
//-----------------------------------------------------------------------------
// Name: main()
// Desc: Entry point for the application.
//-----------------------------------------------------------------------------
int main(int argc, char* argv[], char* envp[])
{
HRESULT hr;
int iUserChoice;
int i;
// Init COM so we can use CoCreateInstance
CoInitializeEx(NULL, COINIT_MULTITHREADED);
InitializeCriticalSection(&g_csHostList);
// Process the args
for (i = 1; i < argc, argv[i] != NULL; i++)
{
if( !(strcmp(CMDLINE_REGISTER, argv[i] ) ) )
{
g_bRegister = TRUE;
g_wszPath = new WCHAR[strlen(argv[0]) + 1];
if( !g_wszPath)
{
printf("Failed allocating string\n");
goto LCleanup;
}
MultiByteToWideChar(CP_ACP, 0, argv[0], -1, g_wszPath, strlen(argv[0]) + 1);
}
else if( !strcmp(CMDLINE_UNREGISTER, argv[i]))
{
g_bUnRegister = TRUE;
}
else if( !strcmp("-?", argv[i]))
{
printf("\nUsage: register/unregister\n");
goto LCleanup;
}
}
// Init the DirectPlay system
if( FAILED( hr = InitDirectPlay() ) )
{
printf("Failed Initializing DirectPlay: 0x%X\n", hr);
goto LCleanup;
}
if( g_bRegister )
{
if( FAILED( hr = Register() ) )
{
printf("Failed To Register: 0x%X\n", hr);
}
goto LCleanup;
}
else if( g_bUnRegister )
{
if( FAILED( hr = UnRegister() ) )
{
printf("Failed To Unregister: 0x%X\n", hr);
}
goto LCleanup;
}
// See if we were lobby launched or not
if( g_bLobbyLaunched )
{
if( FAILED( hr = LobbyLaunch() ) )
{
printf("Failed be Lobby Launched: 0x%X\n", hr);
goto LCleanup;
}
}
else
{
// Get the necessary user input on whether they are hosting or connecting
do
{
printf("Please select one.\n1. Host\n2. Connect\n");
scanf("%d", &iUserChoice);
} while (iUserChoice != USER_HOST && iUserChoice != USER_CONNECT);
if( FAILED( hr = CreateDeviceAddress() ) )
{
printf("Failed CreatingDeviceAddress: 0x%X\n", hr);
goto LCleanup;
}
if( iUserChoice == USER_HOST )
{
g_bHost = TRUE;
if( FAILED( hr = HostSession() ) )
{
printf("Failed Hosting: 0x%X\n", hr);
goto LCleanup;
}
}
else
{
g_bHost = FALSE;
if( FAILED( hr = EnumDirectPlayHosts() ) )
{
printf("Failed Enumerating Host: 0x%X\n", hr);
goto LCleanup;
}
if( FAILED( hr = ConnectToSession() ) )
{
printf("Failed Connect to Host: 0x%X\n", hr);
goto LCleanup;
}
else
{
printf("\nConnection Successful.\n");
}
}
}
// Init DirectVoice
if( FAILED( hr = InitDirectPlayVoice() ) )
{
printf("Failed Initializing DirectVoice: 0x%X\n", hr);
goto LCleanup;
}
// Present User with Choices
do
{
printf("Please select one.\n1. Exit\n2. Send Data\n");
scanf("%d", &iUserChoice);
if( iUserChoice == USER_SEND )
{
if( FAILED( hr = SendDirectPlayMessage() ) )
{
printf("Failed To Send Data: 0x%X\n", hr);
goto LCleanup;
}
}
} while (iUserChoice != USER_EXIT);
LCleanup:
CleanupDirectPlay();
// ShutDown COM
CoUninitialize();
return 0;
}
//-----------------------------------------------------------------------------
// Name: InitDirectPlay()
// Desc: Initialize DirectPlay
//-----------------------------------------------------------------------------
HRESULT InitDirectPlay()
{
HRESULT hr = S_OK;
// Create the IDirectPlay8Peer Object
if( FAILED( hr = CoCreateInstance(CLSID_DirectPlay8Peer, NULL,
CLSCTX_INPROC_SERVER,
IID_IDirectPlay8Peer,
(LPVOID*) &g_pDP ) ) )
{
printf("Failed Creating the IDirectPlay8Peer Object: 0x%X\n", hr);
goto LCleanup;
}
// Create the IDirectPlay8LobbiedApplication Object
if( FAILED( hr = CoCreateInstance(CLSID_DirectPlay8LobbiedApplication, NULL,
CLSCTX_INPROC_SERVER,
IID_IDirectPlay8LobbiedApplication,
(LPVOID*) &g_pLobbyApp ) ) )
{
printf("Failed Creating the IDirectPlay8LobbiedApplication Object: 0x%X\n", hr);
goto LCleanup;
}
// Init DirectPlay
if( FAILED( hr = g_pDP->Initialize(NULL, DirectPlayMessageHandler, 0 ) ) )
{
printf("Failed Initializing DirectPlay: 0x%X\n", hr);
goto LCleanup;
}
// Init the Lobby interface
if( FAILED( hr = g_pLobbyApp->Initialize(NULL, LobbyAppMessageHandler, &g_hLobbyHandle, 0 ) ) )
{
printf("Failed Initializing Lobby: 0x%X\n", hr);
goto LCleanup;
}
else
g_bLobbyLaunched = g_hLobbyHandle != NULL;
// Ensure that TCP/IP is a valid Service Provider
if( FALSE == IsServiceProviderValid(&CLSID_DP8SP_TCPIP ) )
{
hr = E_FAIL;
printf("Failed validating CLSID_DP8SP_TCPIP");
goto LCleanup;
}
LCleanup:
return hr;
}
//-----------------------------------------------------------------------------
// Name: IsServiceProviderValid()
// Desc: Return TRUE if the service provider is valid
//-----------------------------------------------------------------------------
BOOL IsServiceProviderValid(const GUID* pGuidSP)
{
HRESULT hr;
DPN_SERVICE_PROVIDER_INFO* pdnSPInfo = NULL;
DWORD dwItems = 0;
DWORD dwSize = 0;
hr = g_pDP->EnumServiceProviders(&CLSID_DP8SP_TCPIP, NULL, NULL, &dwSize, &dwItems, 0);
if( hr != DPNERR_BUFFERTOOSMALL)
{
printf("Failed Enumerating Service Providers: 0x%x\n", hr);
goto LCleanup;
}
pdnSPInfo = (DPN_SERVICE_PROVIDER_INFO*) new BYTE[dwSize];
if( FAILED( hr = g_pDP->EnumServiceProviders(&CLSID_DP8SP_TCPIP, NULL, pdnSPInfo, &dwSize, &dwItems, 0 ) ) )
{
printf("Failed Enumerating Service Providers: 0x%x\n", hr);
goto LCleanup;
}
// There are no items returned so the requested SP is not available
if( dwItems == 0)
{
hr = E_FAIL;
}
LCleanup:
SAFE_DELETE_ARRAY(pdnSPInfo);
if( SUCCEEDED(hr) )
return TRUE;
else
return FALSE;
}
//-----------------------------------------------------------------------------
// Name: DirectPlayMessageHandler
// Desc: Handler for DirectPlay messages.
//-----------------------------------------------------------------------------
HRESULT WINAPI DirectPlayMessageHandler(PVOID pvUserContext, DWORD dwMessageId, PVOID pMsgBuffer)
{
HRESULT hr = S_OK;
switch (dwMessageId)
{
case DPN_MSGID_ENUM_HOSTS_RESPONSE:
{
PDPNMSG_ENUM_HOSTS_RESPONSE pEnumHostsResponseMsg;
const DPN_APPLICATION_DESC* pAppDesc;
HOST_NODE* pHostNode = NULL;
WCHAR* pwszSession = NULL;
pEnumHostsResponseMsg = (PDPNMSG_ENUM_HOSTS_RESPONSE) pMsgBuffer;
pAppDesc = pEnumHostsResponseMsg->pApplicationDescription;
// Insert each host response if it isn't already present
EnterCriticalSection(&g_csHostList);
for (pHostNode = g_pHostList; pHostNode; pHostNode = pHostNode->pNext)
{
if( pAppDesc->guidInstance == pHostNode->pAppDesc->guidInstance)
{
// This host is already in the list
pHostNode = NULL;
goto Break_ENUM_HOSTS_RESPONSE;
}
}
// This host session is not in the list then so insert it.
pHostNode = new HOST_NODE;
if( pHostNode == NULL)
{
goto Break_ENUM_HOSTS_RESPONSE;
}
ZeroMemory(pHostNode, sizeof(HOST_NODE));
// Copy the Host Address
if( FAILED( pEnumHostsResponseMsg->pAddressSender->Duplicate(&pHostNode->pHostAddress ) ) )
{
goto Break_ENUM_HOSTS_RESPONSE;
}
pHostNode->pAppDesc = new DPN_APPLICATION_DESC;
if( pHostNode == NULL)
{
goto Break_ENUM_HOSTS_RESPONSE;
}
ZeroMemory(pHostNode->pAppDesc, sizeof(DPN_APPLICATION_DESC));
memcpy(pHostNode->pAppDesc, pAppDesc, sizeof(DPN_APPLICATION_DESC));
// Null out all the pointers we aren't copying
pHostNode->pAppDesc->pwszSessionName = NULL;
pHostNode->pAppDesc->pwszPassword = NULL;
pHostNode->pAppDesc->pvReservedData = NULL;
pHostNode->pAppDesc->dwReservedDataSize = 0;
pHostNode->pAppDesc->pvApplicationReservedData = NULL;
pHostNode->pAppDesc->dwApplicationReservedDataSize = 0;
if( pAppDesc->pwszSessionName)
{
pwszSession = new WCHAR[wcslen(pAppDesc->pwszSessionName) + 1];
if( pwszSession)
{
wcscpy(pwszSession, pAppDesc->pwszSessionName);
}
}
pHostNode->pwszSessionName = pwszSession;
// Insert it onto the front of the list
pHostNode->pNext = g_pHostList ? g_pHostList->pNext : NULL;
g_pHostList = pHostNode;
pHostNode = NULL;
Break_ENUM_HOSTS_RESPONSE:
LeaveCriticalSection(&g_csHostList);
if( pHostNode)
{
SAFE_RELEASE(pHostNode->pHostAddress);
SAFE_DELETE(pHostNode->pAppDesc);
delete pHostNode;
}
break;
}
case DPN_MSGID_RECEIVE:
{
PDPNMSG_RECEIVE pMsg;
pMsg = (PDPNMSG_RECEIVE) pMsgBuffer;
printf("\nReceived Message: %S\n", (WCHAR*)pMsg->pReceiveData);
break;
}
case DPN_MSGID_HOST_MIGRATE:
{
PDPNMSG_HOST_MIGRATE pHostMigrateMsg;
pHostMigrateMsg = (PDPNMSG_HOST_MIGRATE) pMsgBuffer;
printf("\nHost Migration Has Occured.\n");
// See if we are the new host
if( pHostMigrateMsg->dpnidNewHost == g_dpnidLocalPlayer)
printf("You are the New Host\n");
else
printf("DPNID of New Host is %d\n", pHostMigrateMsg->dpnidNewHost);
break;
}
case DPN_MSGID_CREATE_PLAYER:
{
PDPNMSG_CREATE_PLAYER pCreatePlayerMsg;
DWORD dwSize = 0;
DPN_PLAYER_INFO* pdpPlayerInfo = NULL;
pCreatePlayerMsg = (PDPNMSG_CREATE_PLAYER)pMsgBuffer;
// check to see if we are the player being created
hr = g_pDP->GetPeerInfo(pCreatePlayerMsg->dpnidPlayer, pdpPlayerInfo, &dwSize, 0);
if( FAILED( hr) && hr != DPNERR_BUFFERTOOSMALL)
{
printf("Failed GetPeerInfo: 0x%X\n", hr);
return hr;
}
pdpPlayerInfo = (DPN_PLAYER_INFO*) new BYTE[dwSize];
ZeroMemory(pdpPlayerInfo, dwSize);
pdpPlayerInfo->dwSize = sizeof(DPN_PLAYER_INFO);
if( FAILED( hr = g_pDP->GetPeerInfo(pCreatePlayerMsg->dpnidPlayer, pdpPlayerInfo, &dwSize, 0 ) ) )
{
printf("Failed GetPeerInfo: 0x%X\n", hr);
goto Error_DPN_MSGID_CREATE_PLAYER;
}
if( pdpPlayerInfo->dwPlayerFlags & DPNPLAYER_LOCAL)
g_dpnidLocalPlayer = pCreatePlayerMsg->dpnidPlayer;
Error_DPN_MSGID_CREATE_PLAYER:
SAFE_DELETE_ARRAY(pdpPlayerInfo);
break;
}
}
return hr;
}
//-----------------------------------------------------------------------------
// Name: LobbyAppMessageHandler
// Desc: Handler for DirectPlay lobby messages
//-----------------------------------------------------------------------------
HRESULT WINAPI LobbyAppMessageHandler(PVOID pvUserContext, DWORD dwMessageId, PVOID pMsgBuffer)
{
HRESULT hr = S_OK;
switch (dwMessageId)
{
case DPL_MSGID_CONNECT:
{
PDPL_MESSAGE_CONNECT pConnectMsg;
PDPL_CONNECTION_SETTINGS pSettings;
pConnectMsg = (PDPL_MESSAGE_CONNECT)pMsgBuffer;
pSettings = pConnectMsg->pdplConnectionSettings;
// Register the lobby with directplay so we get automatic notifications
hr = g_pDP->RegisterLobby(pConnectMsg->hConnectId, g_pLobbyApp, DPNLOBBY_REGISTER);
break;
}
}
return hr;
}
//-----------------------------------------------------------------------------
// Name: DirectVoiceServerMessageHandler
// Desc: Handler for DirectPlay Voice server messages
//-----------------------------------------------------------------------------
HRESULT WINAPI DirectVoiceServerMessageHandler(PVOID pvUserContext, DWORD dwMessageId, PVOID pMsgBuffer)
{
// In this app we are not responding to any server messages
return S_OK;
}
//-----------------------------------------------------------------------------
// Name: DirectVoiceClientMessageHandler
// Desc: Handler for DirectPlay Voice client messages
//-----------------------------------------------------------------------------
HRESULT WINAPI DirectVoiceClientMessageHandler(PVOID pvUserContext, DWORD dwMessageId, PVOID pMsgBuffer)
{
HRESULT hr = S_OK;
switch(dwMessageId)
{
case DVMSGID_RECORDSTART:
{
printf("Record Start\n");
break;
}
case DVMSGID_RECORDSTOP:
{
printf("Record Stop\n");
break;
}
}
return hr;
}
//-----------------------------------------------------------------------------
// Name: EnumDirectPlayHosts()
// Desc: Enumerates the hosts
//-----------------------------------------------------------------------------
HRESULT EnumDirectPlayHosts()
{
HRESULT hr = S_OK;
WCHAR wszHost[128];
DPN_APPLICATION_DESC dpAppDesc;
WCHAR* pwszURL = NULL;
// Prompt for the hostname/ip
printf("\nPlease enter the IP address of host:\n");
wscanf(L"%ls", wszHost);
if( FAILED( hr = CreateHostAddress(wszHost ) ) )
{
printf("Failed Creating Host Address: 0x%X\n", hr);
goto LCleanup;
}
// Now set up the Application Description
ZeroMemory(&dpAppDesc, sizeof(DPN_APPLICATION_DESC));
dpAppDesc.dwSize = sizeof(DPN_APPLICATION_DESC);
dpAppDesc.guidApplication = g_guidApp;
// We now have the host address so lets enum
if( FAILED( hr = g_pDP->EnumHosts(&dpAppDesc, // pApplicationDesc
g_pHostAddress, // pdpaddrHost
g_pDeviceAddress, // pdpaddrDeviceInfo
NULL, 0, // pvUserEnumData, size
4, // dwEnumCount
0, // dwRetryInterval
0, // dwTimeOut
NULL, // pvUserContext
NULL, // pAsyncHandle
DPNENUMHOSTS_SYNC ) ) )// dwFlags
{
printf("Failed Enumerating the Hosts: 0x%X\n", hr);
goto LCleanup;
}
LCleanup:
return hr;
}
//-----------------------------------------------------------------------------
// Name: CreateDeviceAddress()
// Desc: Creates a device address
//-----------------------------------------------------------------------------
HRESULT CreateDeviceAddress()
{
HRESULT hr = S_OK;
// Create our IDirectPlay8Address Device Address
if( FAILED( hr = CoCreateInstance(CLSID_DirectPlay8Address, NULL,
CLSCTX_INPROC_SERVER,
IID_IDirectPlay8Address,
(LPVOID*) &g_pDeviceAddress ) ) )
{
printf("Failed Creating the IDirectPlay8Address Object: 0x%X\n", hr);
goto LCleanup;
}
// Set the SP for our Device Address
if( FAILED( hr = g_pDeviceAddress->SetSP(&CLSID_DP8SP_TCPIP ) ) )
{
printf("Failed Setting the Service Provider: 0x%X\n", hr);
goto LCleanup;
}
LCleanup:
return hr;
}
//-----------------------------------------------------------------------------
// Name: CreateHostAddress()
// Desc: Creates a host address
//-----------------------------------------------------------------------------
HRESULT CreateHostAddress(WCHAR* pwszHost)
{
HRESULT hr = S_OK;
// Create our IDirectPlay8Address Host Address
if( FAILED( hr = CoCreateInstance(CLSID_DirectPlay8Address, NULL,
CLSCTX_INPROC_SERVER,
IID_IDirectPlay8Address,
(LPVOID*) &g_pHostAddress ) ) )
{
printf("Failed Creating the IDirectPlay8Address Object: 0x%X\n", hr);
goto LCleanup;
}
// Set the SP for our Host Address
if( FAILED( hr = g_pHostAddress->SetSP(&CLSID_DP8SP_TCPIP ) ) )
{
printf("Failed Setting the Service Provider: 0x%X\n", hr);
goto LCleanup;
}
// Set the hostname into the address
if( FAILED( hr = g_pHostAddress->AddComponent(DPNA_KEY_HOSTNAME, pwszHost,
2*(wcslen(pwszHost) + 1), /*bytes*/
DPNA_DATATYPE_STRING ) ) )
{
printf("Failed Adding Hostname to Host Address: 0x%X\n", hr);
goto LCleanup;
}
LCleanup:
return hr;
}
//-----------------------------------------------------------------------------
// Name: HostSession()
// Desc: Host a DirectPlay session
//-----------------------------------------------------------------------------
HRESULT HostSession()
{
HRESULT hr = S_OK;
DPN_APPLICATION_DESC dpAppDesc;
WCHAR wszSession[128];
// Prompt the user for the session name
printf("\nPlease Enter a Session Name.\n");
wscanf(L"%ls", wszSession);
// Now set up the Application Description
ZeroMemory(&dpAppDesc, sizeof(DPN_APPLICATION_DESC));
dpAppDesc.dwSize = sizeof(DPN_APPLICATION_DESC);
dpAppDesc.guidApplication = g_guidApp;
dpAppDesc.pwszSessionName = wszSession;
dpAppDesc.dwFlags = DPNSESSION_MIGRATE_HOST;
// We are now ready to host the app
if( FAILED( hr = g_pDP->Host(&dpAppDesc, // AppDesc
&g_pDeviceAddress, 1, // Device Address
NULL, NULL, // Reserved
NULL, // Player Context
0 ) ) ) // dwFlags
{
printf("Failed Hosting: 0x%X\n", hr);
goto LCleanup;
}
else
{
printf("Currently Hosting...\n");
}
LCleanup:
return hr;
}
//-----------------------------------------------------------------------------
// Name: ConnectToSession()
// Desc: Connects to a DirectPlay session
//-----------------------------------------------------------------------------
HRESULT ConnectToSession()
{
HRESULT hr = E_FAIL;
DPN_APPLICATION_DESC dpnAppDesc;
IDirectPlay8Address* pHostAddress = NULL;
ZeroMemory(&dpnAppDesc, sizeof(DPN_APPLICATION_DESC));
dpnAppDesc.dwSize = sizeof(DPN_APPLICATION_DESC);
dpnAppDesc.guidApplication = g_guidApp;
// Simply connect to the first one in the list
EnterCriticalSection(&g_csHostList);
if( g_pHostList && SUCCEEDED(hr = g_pHostList->pHostAddress->Duplicate(&pHostAddress ) ) )
{
hr = g_pDP->Connect(&dpnAppDesc, // pdnAppDesc
pHostAddress, // pHostAddr
g_pDeviceAddress, // pDeviceInfo
NULL, // pdnSecurity
NULL, // pdnCredentials
NULL, 0, // pvUserConnectData/Size
NULL, // pvPlayerContext
NULL, // pvAsyncContext
NULL, // pvAsyncHandle
DPNCONNECT_SYNC); // dwFlags
if( FAILED( hr))
printf("Failed Connecting to Host: 0x%x\n", hr);
}
else
{
printf("Failed Duplicating Host Address: 0x%x\n", hr);
}
LeaveCriticalSection(&g_csHostList);
SAFE_RELEASE(pHostAddress);
return hr;
}
//-----------------------------------------------------------------------------
// Name: SendDirectPlayMessage()
// Desc: Sends a DirectPlay message to all players
//-----------------------------------------------------------------------------
HRESULT SendDirectPlayMessage()
{
HRESULT hr = S_OK;
DPN_BUFFER_DESC dpnBuffer;
WCHAR wszData[256];
// Get the data from the user
printf("\nPlease Enter a String.\n");
wscanf(L"%ls", wszData);
dpnBuffer.pBufferData = (BYTE*) wszData;
dpnBuffer.dwBufferSize = 2 * (wcslen(wszData) + 1);
if( FAILED( hr = g_pDP->SendTo(DPNID_ALL_PLAYERS_GROUP, // dpnid
&dpnBuffer, // pBufferDesc
1, // cBufferDesc
0, // dwTimeOut
NULL, // pvAsyncContext
NULL, // pvAsyncHandle
DPNSEND_SYNC |
DPNSEND_NOLOOPBACK ) ) ) // dwFlags
{
printf("Failed Sending Data: 0x%x\n", hr);
}
return hr;
}
//-----------------------------------------------------------------------------
// Name: Register()
// Desc: Register app as lobby launchable
//-----------------------------------------------------------------------------
HRESULT Register()
{
HRESULT hr = S_OK;
DPL_PROGRAM_DESC dplDesc;
WCHAR* pwszPath = NULL;
WCHAR* pwszExecutable = NULL;
int i;
ZeroMemory(&dplDesc, sizeof(DPL_PROGRAM_DESC));
dplDesc.dwSize = sizeof(DPL_PROGRAM_DESC);
dplDesc.guidApplication = g_guidApp;
// We need to parse out the path and the exe name from the input value
for (i = wcslen(g_wszPath); i >=0 && g_wszPath[i] != L'\\'; i--);
pwszPath = new WCHAR[i + 1];
if( pwszPath == NULL)
{
printf("Failed parsing path.");
hr = E_FAIL;
goto LCleanup;
}
wcsncpy(pwszPath, g_wszPath, i);
pwszPath[i] = L'\0';
pwszExecutable = g_wszPath + i + 1;
dplDesc.pwszApplicationName = pwszExecutable;
dplDesc.pwszExecutableFilename = pwszExecutable;
dplDesc.pwszExecutablePath = pwszPath;
hr = g_pLobbyApp->RegisterProgram(&dplDesc, 0);
LCleanup:
SAFE_DELETE_ARRAY(pwszPath);
return hr;
}
//-----------------------------------------------------------------------------
// Name: UnRegister()
// Desc: Unregister app as lobby launchable
//-----------------------------------------------------------------------------
HRESULT UnRegister()
{
HRESULT hr = S_OK;
hr = g_pLobbyApp->UnRegisterProgram(&g_guidApp, 0);
return hr;
}
//-----------------------------------------------------------------------------
// Name: LobbyLaunch()
// Desc: Host or connect to session based on lobby launch settings
//-----------------------------------------------------------------------------
HRESULT LobbyLaunch()
{
HRESULT hr = S_OK;
DPL_CONNECTION_SETTINGS* pSettings = NULL;
DWORD dwSettingsSize = 0;
// Get the lobby connection data
// First see how big a buffer we need
hr = g_pLobbyApp->GetConnectionSettings(g_hLobbyHandle, pSettings, &dwSettingsSize, 0);
if( hr != DPNERR_BUFFERTOOSMALL)
{
printf("Failed GetConnectionSettings: 0x%x\n", hr);
goto LCleanup;
}
pSettings = (DPL_CONNECTION_SETTINGS*) new BYTE[dwSettingsSize];
if( pSettings == NULL)
{
printf("Failed Allocating Buffer: 0x%x\n");
hr = E_FAIL;
goto LCleanup;
}
if( FAILED( hr = g_pLobbyApp->GetConnectionSettings(g_hLobbyHandle, pSettings, &dwSettingsSize, 0 ) ) )
{
printf("Failed GetConnectionSettings: 0x%x\n", hr);
goto LCleanup;
}
if( g_bHost = pSettings->dwFlags & DPLCONNECTSETTINGS_HOST)
{
// We are to host the game
if( FAILED( hr = g_pDP->Host(&pSettings->dpnAppDesc, // dpnAppDesc
pSettings->ppdp8DeviceAddresses,// prgpDeviceInfo
pSettings->cNumDeviceAddresses, // cDeviceInfo
NULL, NULL, // Security
NULL, // pvPlayerContext
0 ) ) ) // dwFlags
{
printf("Failed Host: 0x%x\n", hr);
goto LCleanup;
}
}
else
{
// We need to connect
if( FAILED( hr = g_pDP->Connect(&pSettings->dpnAppDesc, // pdnAppDesc
pSettings->pdp8HostAddress, // pHostAddr
pSettings->ppdp8DeviceAddresses[0], // pDeviceInfo
NULL, NULL, // Security
NULL, 0, // pvUserConnectData/Size
NULL, // pvPlayerContext
NULL, NULL, // pvAsyncContext/Handle
DPNCONNECT_SYNC ) ) ) // dwFlags
{
printf("Failed Lobby App Connect: 0x%x\n", hr);
goto LCleanup;
}
}
LCleanup:
if( pSettings)
{
SAFE_RELEASE(pSettings->pdp8HostAddress);
for (DWORD dwIndex = 0; dwIndex < pSettings->cNumDeviceAddresses; dwIndex++)
{
SAFE_RELEASE(pSettings->ppdp8DeviceAddresses[dwIndex]);
}
}
SAFE_DELETE_ARRAY(pSettings);
return hr;
}
//-----------------------------------------------------------------------------
// Name: InitDirectPlayVoice()
// Desc: Initialize DirectPlay Voice
//-----------------------------------------------------------------------------
HRESULT InitDirectPlayVoice()
{
HRESULT hr = S_OK;
DVSESSIONDESC dvSessionDesc;
DVSOUNDDEVICECONFIG dvSoundDeviceConfig;
DVCLIENTCONFIG dvClientConfig;
DVID dvid;
// Init the server if we are the host
if( g_bHost )
{
// Create the IDirectPlayVoiceServer Object
if( FAILED( hr = CoCreateInstance(CLSID_DirectPlayVoiceServer, NULL,
CLSCTX_INPROC_SERVER,
IID_IDirectPlayVoiceServer,
(LPVOID*) &g_pVoiceServer ) ) )
{
printf("Failed Creating the IDirectPlayVoiceServer Object: 0x%X\n", hr);
goto LCleanup;
}
// Init the Voice server
if( FAILED( hr = g_pVoiceServer->Initialize(g_pDP, DirectVoiceServerMessageHandler, NULL, 0, 0 ) ) )
{
printf("Failed Initializing the IDirectPlayVoiceServer Object: 0x%X\n", hr);
goto LCleanup;
}
ZeroMemory(&dvSessionDesc, sizeof(DVSESSIONDESC));
dvSessionDesc.dwSize = sizeof(DVSESSIONDESC);
dvSessionDesc.dwSessionType = DVSESSIONTYPE_PEER;
dvSessionDesc.dwBufferQuality = DVBUFFERQUALITY_DEFAULT;
dvSessionDesc.guidCT = DPVCTGUID_DEFAULT;
dvSessionDesc.dwBufferAggressiveness = DVBUFFERAGGRESSIVENESS_DEFAULT;
if( FAILED( hr = g_pVoiceServer->StartSession(&dvSessionDesc, 0 ) ) )
{
printf("Failed Starting the Session: 0x%X\n", hr);
goto LCleanup;
}
}
// Test DirectVoice
if( FAILED( hr = TestDirectVoice() ) )
{
printf("Failed Testing DirectVoice: 0x%X\n", hr);
goto LCleanup;
}
// Init the client and the connection
// Create the IDirectPlayVoiceClient Object
if( FAILED( hr = CoCreateInstance(CLSID_DirectPlayVoiceClient, NULL,
CLSCTX_INPROC_SERVER,
IID_IDirectPlayVoiceClient,
(LPVOID*) &g_pVoiceClient ) ) )
{
printf("Failed Creating the IDirectPlayVoiceClient Object: 0x%X\n", hr);
goto LCleanup;
}
// Init the Voice client
if( FAILED( hr = g_pVoiceClient->Initialize(g_pDP, DirectVoiceClientMessageHandler, NULL, 0, 0 ) ) )
{
printf("Failed Initializing the IDirectPlayVoiceClient Object: 0x%X\n", hr);
goto LCleanup;
}
ZeroMemory(&dvSoundDeviceConfig, sizeof(DVSOUNDDEVICECONFIG));
dvSoundDeviceConfig.dwSize = sizeof(DVSOUNDDEVICECONFIG);
dvSoundDeviceConfig.dwFlags = DVSOUNDCONFIG_AUTOSELECT;
dvSoundDeviceConfig.guidPlaybackDevice = DSDEVID_DefaultVoicePlayback;
dvSoundDeviceConfig.lpdsPlaybackDevice = NULL;
dvSoundDeviceConfig.guidCaptureDevice = DSDEVID_DefaultVoiceCapture;
dvSoundDeviceConfig.lpdsCaptureDevice = NULL;
dvSoundDeviceConfig.hwndAppWindow = GetConsoleHwnd();
dvSoundDeviceConfig.lpdsMainBuffer = NULL;
dvSoundDeviceConfig.dwMainBufferFlags = 0;
dvSoundDeviceConfig.dwMainBufferPriority = 0;
ZeroMemory(&dvClientConfig, sizeof(DVCLIENTCONFIG));
dvClientConfig.dwSize = sizeof(DVCLIENTCONFIG);
dvClientConfig.dwFlags = DVCLIENTCONFIG_AUTOVOICEACTIVATED | DVCLIENTCONFIG_AUTORECORDVOLUME;
dvClientConfig.lRecordVolume = DVRECORDVOLUME_LAST;
dvClientConfig.lPlaybackVolume = DVPLAYBACKVOLUME_DEFAULT;
dvClientConfig.dwThreshold = DVTHRESHOLD_UNUSED;
dvClientConfig.dwBufferQuality = DVBUFFERQUALITY_DEFAULT;
dvClientConfig.dwBufferAggressiveness = DVBUFFERAGGRESSIVENESS_DEFAULT;
dvClientConfig.dwNotifyPeriod = 0;
if( FAILED( hr = g_pVoiceClient->Connect(&dvSoundDeviceConfig, &dvClientConfig, DVFLAGS_SYNC ) ) )
{
printf("Failed DirectVoice Client Connect: 0x%X\n", hr);
goto LCleanup;
}
dvid = DVID_ALLPLAYERS;
if( FAILED( hr = g_pVoiceClient->SetTransmitTargets(&dvid, 1, 0 ) ) )
{
printf("Failed SetTransmitTargets: 0x%X\n", hr);
goto LCleanup;
}
LCleanup:
return hr;
}
//-----------------------------------------------------------------------------
// Name: TestDirectVoice()
// Desc: Tests that DirectPlay Voice is has been setup, and if it hasn't,
// it runs the DirectPlay Voice setup wizard.
//-----------------------------------------------------------------------------
HRESULT TestDirectVoice()
{
HRESULT hr = S_OK;
IDirectPlayVoiceTest* pVoiceTest = NULL;
GUID guidPlayback;
GUID guidCapture;
HWND hwnd;
// Create the IDirectPlayVoiceTest Object
if( FAILED( hr = CoCreateInstance(CLSID_DirectPlayVoiceTest, NULL,
CLSCTX_INPROC_SERVER,
IID_IDirectPlayVoiceTest,
(LPVOID*) &pVoiceTest ) ) )
{
printf("Failed Creating the IDirectPlayVoiceTest Object: 0x%X\n", hr);
goto LCleanup;
}
guidPlayback = DSDEVID_DefaultVoicePlayback;
guidCapture = DSDEVID_DefaultVoiceCapture;
hr = pVoiceTest->CheckAudioSetup(&guidPlayback, &guidCapture, NULL, DVFLAGS_QUERYONLY);
if( hr == DVERR_RUNSETUP)
{
hwnd = GetConsoleHwnd();
if( FAILED( hr = pVoiceTest->CheckAudioSetup(&guidPlayback, &guidCapture, hwnd, DVFLAGS_ALLOWBACK ) ) )
{
printf("Failed CheckAudioSetup: 0x%X\n", hr);
goto LCleanup;
}
}
else if( FAILED( hr))
{
printf("Failed CheckAudioSetup: 0x%X\n", hr);
goto LCleanup;
}
LCleanup:
SAFE_RELEASE(pVoiceTest);
return hr;
}
//-----------------------------------------------------------------------------
// Name: GetConsoleHwnd()
// Desc: Returns the console HWND
//-----------------------------------------------------------------------------
HWND GetConsoleHwnd()
{
HWND hwndFound; // This is what is returned to the caller.
char pszNewWindowTitle[1024]; // Contains fabricated WindowTitle.
char pszOldWindowTitle[1024]; // Contains original WindowTitle.
// Fetch current window title.
GetConsoleTitle(pszOldWindowTitle, 1024);
// Format a "unique" NewWindowTitle.
wsprintf(pszNewWindowTitle,"%d/%d", GetTickCount(), GetCurrentProcessId());
// Change current window title.
SetConsoleTitle(pszNewWindowTitle);
// Ensure window title has been updated.
Sleep(40);
// Look for NewWindowTitle.
hwndFound=FindWindow(NULL, pszNewWindowTitle);
// Restore original window title.
SetConsoleTitle(pszOldWindowTitle);
return(hwndFound);
}
//-----------------------------------------------------------------------------
// Name: CleanupDirectPlay()
// Desc: Cleanup DirectPlay
//-----------------------------------------------------------------------------
void CleanupDirectPlay()
{
HOST_NODE* pHostNode = NULL;
HOST_NODE* pHostNodetmp = NULL;
// Shutdown DirectVoice
if( g_pVoiceClient)
{
g_pVoiceClient->Disconnect(DVFLAGS_SYNC);
}
if( g_pVoiceServer)
{
g_pVoiceServer->StopSession(0);
}
// Shutdown DirectPlay
if( g_pDP)
g_pDP->Close(0);
if( g_pLobbyApp)
g_pLobbyApp->Close(0);
// Clean up Host list
EnterCriticalSection(&g_csHostList);
pHostNode = g_pHostList;
while( pHostNode != NULL )
{
SAFE_RELEASE(pHostNode->pHostAddress);
SAFE_DELETE(pHostNode->pAppDesc);
SAFE_DELETE(pHostNode->pwszSessionName);
pHostNodetmp = pHostNode;
pHostNode = pHostNode->pNext;
SAFE_DELETE(pHostNodetmp);
}
LeaveCriticalSection(&g_csHostList);
SAFE_RELEASE(g_pDeviceAddress);
SAFE_RELEASE(g_pHostAddress);
SAFE_RELEASE(g_pDP);
SAFE_RELEASE(g_pLobbyApp);
SAFE_RELEASE(g_pVoiceServer);
SAFE_RELEASE(g_pVoiceClient);
SAFE_DELETE_ARRAY(g_wszPath);
DeleteCriticalSection(&g_csHostList);
}